package com.bdqn.qnnews.schedule.service;

import com.bdqn.qnnews.schedule.api.dto.TaskDto;

import java.util.List;

/**
 * @author xlzhang
 * @date 2024/1/16 9:35
 */
public interface TaskService {

    /**
     * 添加任务
     * @param taskDto 任务数据
     * @return 任务id
     */
    public Long addTask(TaskDto taskDto);

    /**
     * 从延迟队列消费任务
     *  重点：从延迟队列取出符合条件（根据score查询，score小于或等于当前时间毫秒值）
     */
    public List<TaskDto> pollTask(Integer taskTopic);
}
